Active MQ 6.X
Общее описание
Обеспечивает отправку и получение сообщений через брокер ActiveMQ Artemis (версии 6.x). Поддерживает очереди и топики, транзакционную обработку и различные режимы подтверждения сообщений.
Блок ActiveMQ 6.X может использоваться в качестве:
-
блока отправителя
-
блока получателя.
Настройка блока
В данном разделе описаны параметры блока ActiveMQ 6.X, которые необходимо заполнить при его настройке.
Базовые параметры
| Название в UI | Название атрибута | Описание | Значение по умолчанию | Тип данных |
|---|---|---|---|---|
| Dynamic Endpoint | dynamicEndpoint | Доступен только для блоков-отправителей Параметр позволяет включить встроенную функциональность динамического определения вызываемой конечной точки. При включении параметра структура блока меняется таким образом, что в коде вместо определения to проставляется toD, а значение самого вызываемого ресурса может собираться из переменной, например ${header.foo}. | True | Логическое значение |
| Connection | connection | Обязательный параметр Позволяет выбрать предсозданное подключение к серверу или создать новое с помощью визарда Connection Manager. | Список | |
| Description | description | Краткое описание блока. | Строка | |
| Destination Type | destinationType | Тип точки подключения. Возможные значения:
| queue | Строка |
| Destination Name | destinationName | Обязательный параметр Обязательное имя очереди (queue) или топика (topic), используемого в качестве целевого адресата для передачи данных. Параметр определяет, куда будут направляться сообщения. Значение должно соответствовать заранее созданному ресурсу в целевой системе обмена сообщениями. | Строка | |
| Disable Reply To | disableReplyTo | Определяет, должна ли система игнорировать заголовок JMSReplyTo в сообщениях JMS. При true Camel не отправляет ответ в пункт назначения, указанный в заголовке JMSReplyTo. | False | Логическое значение |
| Durable Subscription Name | durableSubscriptionName | Имя постоянной подписки (сохраняется на брокере при отключении клиента). Чтобы пользоваться этой опцией, необходимо задать значение параметру Client ID | Строка | |
| Jms Message Type | jmsMessageType | Позволяет принудительно использовать определенную реализацию jakarta.jms.Message для отправки сообщений JMS. По умолчанию тип сообщения, который будет использоваться, определяется исходя из типа In body. Возможные значения:
| Список | |
| Reply To | replyTo | Задает явного адресата ReplyTo, переопределяя значение Message.getJMSReplyTo(), полученное в исходном сообщении. | Строка | |
| Test Connection On Startup | testConnectionOnStartup | Если True, компонент проверяет доступность AMQP‑сервера при запуске потока. Гарантирует, что соединение установлено до начала обработки сообщений. При ошибке — поток не стартует. | False | Логическое значение |
| Acknowledgement Mode Name | acknowledgementModeName | Доступен только для блоков-получателей Режим подтверждения JMS. Возможные значения:
| AUTO_ACKNOWLEDGE | Строка |
| Artemis Consumer Priority | artemisConsumerPriority | Доступен только для блоков-получателей Определяет приоритет получателя. Влияет на порядок доставки сообщений: сообщения сначала направляются получателям с высшим приоритетом (в режиме round‑robin, если таких несколько); получатели с низким приоритетом получают сообщения, только если высокоприоритетные не готовы обработать или отклонили сообщение (например, из‑за селекторов). Позволяет гарантировать приоритетную обработку критичных потоков данных. | Строка | |
| Async Consumer | asyncConsumer | Доступен только для блоков-получателей Определяет, будет ли JmsConsumer обрабатывать сообщения из JMS‑очереди асинхронно. Если включено (true): JmsConsumer забирает следующее сообщение, пока предыдущее обрабатывается асинхронно (через Asynchronous Routing Engine). Порядок обработки сообщений может нарушаться. Если выключено (false): следующее сообщение забирается только после полной обработки предыдущего. Важно: при включенной транзакции (transacted=true) асинхронная обработка не работает — транзакция выполняется строго синхронно. | False | Логическое значение |
| Auto Startup | autoStartup | Доступен только для блоков-получателей Определяет, должен ли контейнер запускаться автоматически при старте приложения. | True | Логическое значение |
| Cache Level | cacheLevel | Доступен только для блоков-получателей Устанавливает уровень кэширования по идентификатору для базовых ресурсов JMS. Смотрите также параметр Cache Level Name. | Целое число | |
| Cache Level Name | cacheLevelName | Доступен только для блоков-получателей Задает уровень кэширования по имени для базовых ресурсов JMS. Возможные значения:
| CACHE_AUTO | Список |
| Concurrent Consumers | concurrentConsumers | Доступен только для блоков-получателей Указывает количество одновременных получателей по умолчанию при использовании JMS (не для запроса/ответа через JMS). Также для управления динамическим увеличением/уменьшением масштабирования потоков используется параметр Max Messages Per Task. При выполнении запроса/ответа через JMS для управления количеством одновременных получателей в листенере ответных сообщений используется опция Reply To Concurrent Consumers. | 1 | Целое число |
| Max Concurrent Consumers | maxConcurrentConsumers | Доступен только для блоков-получателей Указывает максимальное количество одновременных получателей при использовании JMS (не для запроса/ответа через JMS). Также для управления динамическим увеличением/уменьшением масштабирования потоков используется параметр Max Messages Per Task. При выполнении запроса/ответа через JMS для управления количеством одновременных получателей в листенере ответных сообщений используется опция Reply To Max Concurrent Consumers. | Целое число | |
| Reply To Delivery Persistent | replyToDeliveryPersistent | Доступен только для блоков-получателей Определяет, следует ли использовать постоянную доставку ответов по умолчанию. | True | Логическое значение |
| Selector | selector | Доступен только для блоков-получателей Устанавливает используемый селектор JMS. | Строка | |
| Subscription Durable | subscriptionDurable | Доступен только для блоков-получателей Определяет, следует ли сделать подписку долговременной. Имя долговременной подписки, которое будет использоваться, можно указать с помощью свойства Subscription Name. Установите для этого значения значение True, чтобы зарегистрировать долговременную подписку в сочетании со значением Subscription Name, если только имя класса вашего листенера сообщений не подходит в качестве имени подписки. Параметр есть смысл задавать только при прослушивании топика. | False | Логическое значение |
| Subscription Name | subscriptionName | Доступен только для блоков-получателей Имя подписки. Оно будет применяться для топика с общей или долговременной подпиской. Имя подписки должно быть уникальным в пределах идентификатора клиента JMS для этого клиента. По умолчанию используется имя класса указанного листенера. Для каждой подписки разрешен только один единовременный получатель (который используется по умолчанию в этом контейнере для прослушивания сообщений), за исключением общей подписки (для которой требуется JMS 2.0). | Строка | |
| Subscription Shared | subscriptionShared | Доступен только для блоков-получателей Определяет, следует ли делать подписку общей. Имя общей подписки можно указать с помощью параметра Subscription Name. Установите для этого параметра значение True, чтобы зарегистрировать общую подписку в сочетании со значением Subscription Name (если только имя вашего класса листенера сообщений не подходит в качестве имени подписки). | False | Логическое значение |
| Delivery Delay | deliveryDelay | Доступен только для блоков-отправителей Устанавливает задержку доставки, которая будет использоваться для отправки вызовов JMS. Для этого параметра требуется брокер, совместимый с JMS 2.0. Значение "-1" отключает задержку. | -1 | Целое число |
| Delivery Mode | deliveryMode | Доступен только для блоков-отправителей Указывает используемый режим доставки. Возможные значения определены в jakarta.jms.DeliveryMode Возможные значения:
| Список | |
| Delivery Persistent | deliveryPersistent | Доступен только для блоков-отправителей Задает, используется ли непрерывная доставка по умолчанию. | True | Логическое значение |
| Explicit Qos Enabled | explicitQosEnabled | Доступен только для блоков-отправителей Определяет, следует ли использовать при отправке сообщений свойства Delivery Mode, Priority или Time To Live. Параметры Delivery Mode, Priority и Time To Live применяются к текущей конечной точке. | False | Логическое значение |
| Format Date Headers To Iso8601 | formatDateHeadersToIso8601 | Доступен только для блоков-отправителей Определяет, следует ли форматировать даты JMS в соответствии со стандартом ISO 8601. | False | Логическое значение |
| Preserve Message Qos | preserveMessageQos | Доступен только для блоков-отправителей Включает отправку сообщений с использованием настроек QoS, указанных в сообщении, а не настроек QoS на конечной точке JMS. Обрабатываются следующие три заголовка: JMSPriority, JMSDeliveryMode и JMSExpiration. Можно указать все или только некоторые из них. Если они не указаны, будут применены значения из конечной точки. При использовании этой опции заголовки переопределяют значения из конечной точки. Опция Explicit Qos Enabled, напротив, будет использовать только параметры, установленные в конечной точке, а не значения из заголовка сообщения. | False | Логическое значение |
| Priority | priority | Доступен только для блоков-отправителей Приоритет сообщения при отправке (где 1 — самый низкий приоритет, а 9 — самый высокий). Чтобы этот параметр работал, также должна быть включена опция Explicit Qos Enabled. | 4 | Список |
| Reply To Concurrent Consumers | replyToConcurrentConsumers | Доступен только для блоков-отправителей Максимальное количество одновременных получателей при использовании запроса/ответа через JMS. Также для управления динамическим увеличением/уменьшением масштабирования потоков применяется параметр Max Messages Per Task. | 1 | Целое число |
| Reply To Max Concurrent Consumers | replyToMaxConcurrentConsumers | Доступен только для блоков-отправителей Максимальное количество одновременных пользователей при использовании запроса/ответа через JMS. Также для управления динамическим увеличением/уменьшением масштабирования потоков применяется параметр Max Messages Per Task. | Целое число | |
| Reply To On Timeout Max Concurrent Consumers | replyToOnTimeoutMaxConcurrent Consumers | Доступен только для блоков-отправителей Указывает максимальное количество одновременных пользователей для продолжения маршрутизации по истечении времени ожидания при использовании запроса/ответа через JMS. | 1 | Целое число |
| Reply To Override | replyToOverride | Доступен только для блоков-отправителей Явное указание адресата ReplyTo в сообщении JMS, которое переопределяет параметр replyTo. Полезно, если нужно переслать сообщение в удаленную очередь и получить ответное сообщение от адресата ReplyTo. | Строка | |
| Reply To Type | replyToType | Доступен только для блоков-отправителей Явное определение того, какой тип стратегии будет использоваться для очередей replyTo при выполнении запроса/ответа через JMS. По умолчанию используются временные очереди. Если replyTo задан, по умолчанию используется общий доступ. Этот параметр позволяет использовать эксклюзивные очереди вместо общих. Возможные значения:
| Список | |
| Request Timeout | requestTimeout | Доступен только для блоков-отправителей Время ожидания ответа при использовании InOut Exchange Pattern (в миллисекундах). Значение по умолчанию — 20 секунд. Можно включить заголовок CamelJmsRequestTimeout, чтобы переопределить это значение тайм‑аута, настроенное для конечной точки, и задать индивидуальные значения тайм‑аута для каждого сообщения. Смотрите также параметр Request Timeout Checker Interval. | 20000 | Длинное целое число |
| Time To Live | timeToLive | Доступен только для блоков-отправителей При отправке сообщений указывает время жизни сообщения в миллисекундах. Значение "-1" означает неограниченное время жизни (бессрочное хранение). | -1 | Целое число |
| Error Handler Logging Level | errorHandlerLoggingLevel | Уровень логирования ErrorHandler по умолчанию для логирования неперехваченных исключений. Возможные значения:
| WARN | Список |
| Error Handler Log Stack Trace | errorHandlerLogStackTrace | Определяет, следует ли логировать трассировку стека или нет с помощью обработчика ошибок по умолчанию. | True | Логическое значение |
| Transacted | transacted | Включает транзакционный режим. | False | Логическое значение |
| Transacted In Out | transactedInOut | Указывает, будут ли операции InOut (ответ на запрос) по умолчанию использоваться в режиме транзакций. | False | Логическое значение |
Расширенные параметры
| Название в UI | Название атрибута | Описание | Значение по умолчанию | Тип данных |
|---|---|---|---|---|
| Allow Additional Headers | allowAdditionalHeaders | Доступен только для блоков-отправителей Разрешает использование дополнительных заголовков, которые могут иметь недопустимые значения в соответствии со спецификацией JMS. Можно указать несколько имен заголовков через запятую — они будут использоваться как суффикс для сопоставления с подстановочными знаками. | Строка | |
| Allow Null Body | allowNullBody | Доступен только для блоков-отправителей Определяет, разрешено ли отправлять сообщения без текста. Если параметр имеет значение False, а текст сообщения равен null, генерируется исключение JMSException. | True | Логическое значение |
| Always Copy Message | alwaysCopyMessage | Доступен только для блоков-отправителей Если значение True, копия сообщения JMS создается всегда, когда оно передается производителю для отправки. Копирование необходимо в некоторых ситуациях — например, когда задано значение replyToDestinationSelectorName. Примечание: Если задан параметр replyToDestinationSelectorName, то значение alwaysCopyMessage будет определяться как True. | False | Логическое значение |
| Correlation Property | correlationProperty | Доступен только для блоков-отправителей Используется при шаблоне обмена InOut: задает свойство JMS вместо стандартного JMSCorrelationID для корреляции сообщений. Если установлено, сообщения коррелируются исключительно по значению этого свойства, а JMSCorrelationID игнорируется. | Строка | |
| Disable Time To Live | disableTimeToLive | Доступен только для блоков-отправителей При включении отключает время жизни сообщения принудительно. | False | Логическое значение |
| Force Send Original Message | forceSendOriginalMessage | Доступен только для блоков-отправителей Если MapJmsMessage=False, при изменении заголовков (get/set) во время потока создается новое JMS‑сообщение для отправки новому получателю. Если параметр установлен в True, отправляется исходное полученное JMS‑сообщение. | False | Логическое значение |
| Include Sent JMSMessage ID | includeSentJMSMessageID | Доступен только для блоков-отправителей Применяется только при отправке получателю JMS с использованием InOnly («отправить и забыть»). При включении добавляет в данные потока фактический идентификатор JMSMessageID, использованный клиентом JMS при отправке сообщения. | False | Логическое значение |
| Lazy Start Producer | lazyStartProducer | Доступен только для блоков-отправителей Определяет, должен ли отправитель стартовать в отложенном режиме (при получении первого сообщения). Отложенный запуск полезен, если запуск отправителя может завершиться неудачей и привести к сбою при старте потока. При отложенном запуске сбой можно обработать во время маршрутизации сообщений с помощью обработчиков ошибок. Примечание: При обработке первого сообщения создание и старт отправителя могут занять время и увеличить общее время обработки. | False | Логическое значение |
| Reply To Cache Level Name | replyToCacheLevelName | Доступен только для блоков-отправителей Устанавливает уровень кэширования по имени для получателя ответа при выполнении запроса/ответа через JMS. Применяется только при использовании фиксированных очередей ответов (не временных).По умолчанию: CACHE_CONSUMER для эксклюзивного/общего доступа с заданным ReplyToSelectorName и CACHE_SESSION для общего доступа без ReplyToSelectorName.При использовании временных очередей CACHE_NONE не разрешен — следует использовать CACHE_CONSUMER или CACHE_SESSION. Возможные значения:
| Список | |
| Reply To Destination Selector Name | replyToDestinationSelectorName | Доступен только для блоков-отправителей Устанавливает селектор JMS с фиксированным именем. Используется для фильтрации собственных ответов от других при работе с общей очередью (если не используется временная очередь ответов). | Строка | |
| Stream Message Type Enabled | streamMessageTypeEnabled | Доступен только для блоков-отправителей Определяет, включен ли тип StreamMessage. Полезная нагрузка потокового типа (файлы, InputStream и т. д.) отправляется либо как BytesMessage, либо как StreamMessage. Параметр задает, какой тип использовать.По умолчанию используется BytesMessage (вся полезная нагрузка считывается в память). При включении полезная нагрузка считывается и записывается в StreamMessage частями. | False | Логическое значение |
| Allow Serialized Headers | allowSerializedHeaders | Определяет, включать ли сериализованные заголовки. Применяется, только если transferExchange=True. Требует, чтобы объекты были сериализуемыми. Несериализуемые объекты исключаются и регистрируются на уровне WARN. | False | Логическое значение |
| Artemis Streaming Enabled | artemisStreamingEnabled | Включает оптимизацию для режима потоковой передачи Apache Artemis. Снижает нагрузку на память при использовании Artemis с типами потоковых сообщений JMS. Должен быть включен только при использовании Apache Artemis. | False | Логическое значение |
| Async Start Listener | asyncStartListener | Определяет, запускать ли асинхронный листенер сообщений JmsConsumer при старте потока. Если JmsConsumer не может установить соединение с удаленным JMS‑брокером, он может заблокироваться при повторных попытках. Установка параметра в True разрешает запуск потоков, пока JmsConsumer подключается к брокеру в асинхронном режиме.Если соединение не удалось установить, регистрируется исключение на уровне WARN, получатель не получает сообщения — поток можно перезапустить для повторной попытки. | False | Логическое значение |
| Async Stop Listener | asyncStopListener | Определяет, следует ли останавливать листенер сообщений JmsConsumer асинхронно при остановке потока. | False | Логическое значение |
| Destination Resolver | destinationResolver | Подключаемый интерфейс стратегии для разрешения назначений JMS. | Строка | |
| Error Handler | errorHandler | Обработчик ошибок типа org.springframework.util.ErrorHandler, вызываемый при необработанных исключениях во время обработки сообщения. Если обработчик не настроен, исключения логируются на уровне WARN. | Строка | |
| Accept Messages While Stopping | acceptMessagesWhileStopping | Доступен только для блоков-получателей Указывает, будет ли получатель принимать сообщения во время остановки. Используйте эту опцию при запуске и остановке потоков JMS во время выполнения, пока в очереди еще есть сообщения. Если параметр имеет значение False и вы останавливаете поток JMS, сообщения могут быть отклонены — тогда JMS‑брокеру придется повторить попытку доставки (которая снова может быть отклонена). В итоге сообщение может попасть в очередь неиспользуемых писем на JMS‑брокере. Чтобы избежать этого, рекомендуется включить опцию. | False | Логическое значение |
| Allow Reply Manager Quick Stop | allowReplyManagerQuickStop | Доступен только для блоков-получателей Функция быстрой остановки включена по умолчанию в обычных получателях JMS. Чтобы включить ее для менеджеров ответов, установите параметр в True. | False | Логическое значение |
| Consumer Type | consumerType | Доступен только для блоков-получателей Тип получателя. Значение параметра определяет, какой листенер Spring JMS использовать. Возможные значения:
| Default | Список |
| Default Task Executor Type | defaultTaskExecutorType | Доступен только для блоков-получателей Определяет, какой тип TaskExecutor по умолчанию использовать в defaultMessageListenerContainer — как для конечных точек‑получателей, так и для replyTo‑получателей, использующихся для конечных точек поставщиковЕсли параметр не задан, по умолчанию используется предыдущее поведение: для конечных точек‑получателей — кэшированный пул потоков, для получателей ответов — SimpleAsync. Рекомендуется использовать ThreadPool, чтобы уменьшить количество ненужных потоков в гибких конфигурациях с динамически изменяющимся числом параллельных получателей. Возможные значения:
| Список | |
| Destination Options | destinationOptions | Доступен только для блоков-получателей Расширенные настройки для JMS‑получателя, задаваемые через синтаксис URL‑запроса в имени назначения. Используются без расширения JMS API. | Строка | |
| Eager Loading Of Properties | eagerLoadingOfProperties | Доступен только для блоков-получателей Позволяет оперативно загружать свойства JMS и полезную нагрузку сразу после загрузки сообщения. Обычно это неэффективно (свойства JMS могут не потребоваться), но иногда помогает заблаговременно выявить проблемы с базовым поставщиком JMS и использованием свойств JMSСмотрите также параметр Eager Poison Body. | False | Логическое значение |
| Eager Poison Body | eagerPoisonBody | Доступен только для блоков-получателей Если включена функция Eager Loading Of Properties, а полезная нагрузка сообщения JMS (тело JMS или свойства JMS) некорректна (не может быть прочитана/сопоставлена), этот параметр задает текст, который будет использован в качестве тела сообщения — чтобы оно могло быть обработано (причина ошибки уже сохранена как исключение в Exchange). Можно отключить, установив значение False. Смотрите также параметр Eager Loading Of Properties. | Poison JMS message due to ${exception.message} | Строка |
| Exception Handler | exceptionHandler | Доступен только для блоков-получателей Пользовательский обработчик исключений. | Строка | |
| Exchange Pattern | exchangePattern | Доступен только для блоков-получателей Задает шаблон взаимодействия между компонентами в интеграционном потоке. Определяет способ передачи сообщений и ожидания ответа. Возможные значения:
| Строка | |
| Expose Listener Session | exposeListenerSession | Доступен только для блоков-получателей Указывает, должен ли быть запущен сеанс прослушивания при получении сообщений. | False | Логическое значение |
| Reply To Consumer Type | replyToConsumerType | Доступен только для блоков-получателей Пользовательский тип получателя ответа при выполнении сценария запрос‑ответ. Возможные значения:
| Default | Список |
| Reply To Same Destination Allowed | replyToSameDestinationAllowed | Доступен только для блоков-получателей Разрешено ли потребителю JMS отправлять ответное сообщение в тот же пункт назначения, который пользователь использует для отправки. Это предотвращает бесконечный цикл, поскольку пользователь получает и отправляет обратно одно и то же сообщение самому себе. | False | Логическое значение |
| Task Executor | taskExecutor | Доступен только для блоков-получателей Позволяет указать пользовательского исполнителя задачи для использования сообщений. | Строка | |
| Wait For Provision Correlation To Be Updated Counter | waitForProvisionCorrelationToBe UpdatedCounter | Количество попыток обновления временного идентификатора корреляции до фактического идентификатора при выполнении запроса/ответа через JMS (при включенном UseMessageIDAsCorrelationID). | 50 | Целое число |
| Wait For Provision Correlation To Be Updated Thread Sleeping Time | waitForProvisionCorrelationToBe UpdatedThreadSleepingTime | Интервал в миллисекундах для перехода в спящий режим при ожидании обновления предварительного идентификатора корреляции. | 100 | Длинное целое число |
| Wait For Temporary Reply To To Be Updated Counter | waitForTemporaryReplyToToBe UpdatedCounter | Количество попыток ожидания создания и готовности временной очереди replyTo при выполнении запроса/ответа через JMS. | 200 | Целое число |
| Exception Listener | exceptionListener | Задает листенер исключений JMS, получающий уведомления о базовых исключениях JMS. | Строка | |
| Header Filter Strategy | headerFilterStrategy | Имя пользовательской стратегии headerFilterStrategy для фильтрации заголовков в сообщении Camel и обратно. | Строка | |
| Idle Consumer Limit | idleConsumerLimit | Ограничивает количество получателей, которые могут простаивать одновременно. | 1 | Целое число |
| Idle Task Execution Limit | idleTaskExecutionLimit | Определяет предел числа запусков в режиме ожидания задачи получения без результата. При достижении предела задача завершается и передает получение другим выполняющимся задачам (в случае динамического планирования). | 1 | Целое число |
| Include All JMSXProperties | includeAllJMSXProperties | Определяет, следует ли включать все свойства с префиксом JMSX при преобразовании из JMS в контекст. При True включаются такие свойства, как JMSXAppID, JMSXUserID и т. д. Примечание: Неприменимо при использовании пользовательской стратегии headerFilterStrategy. | False | Логическое значение |
| Jms Key Format Strategy | jmsKeyFormatStrategy | Подключаемая стратегия кодирования и декодирования ключей JMS для соответствия спецификации. Предоставляются две реализации: default (безопасное использование точек и дефисов) и passthrough (ключ остается как есть). Можно предоставить собственную реализацию (обозначение #). Возможные значения:
| Список | |
| Map Jms Message | mapJmsMessage | Определяет, будет ли полученное JMS‑сообщение автоматически сопоставляться с подходящим типом полезной нагрузки (например, jakarta.jms.TextMessage в строку). | True | Логическое значение |
| Max Messages Per Task | maxMessagesPerTask | Количество сообщений для каждой задачи. Значение "-1" означает отсутствие ограничений. При использовании диапазона одновременных получателей (например, min/max) параметр контролирует, насколько быстро количество получателей будет уменьшаться при снижении нагрузки. | -1 | Целое число |
| Message Converter | messageConverter | Пользовательский преобразователь сообщений Spring (org.springframework.jms.support.converter.MessageConverter) для контроля сопоставления отправляемых/получаемых сообщений с jakarta.jms.Message. | Строка | |
| Message Created Strategy | messageCreatedStrategy | Стратегия, вызываемая при создании новых экземпляров объектов jakarta.jms.Message во время отправки сообщения JMS. | Строка | |
| Message Id Enabled | messageIdEnabled | При отправке указывает, следует ли добавлять идентификаторы сообщений (подсказка для JMS‑брокера). Если брокер принимает подсказку, идентификатор сообщения устанавливается в null; если игнорирует — присваивается уникальное значение. | True | Логическое значение |
| Message Listener Container Factory | messageListenerContainerFactory | Регистрационный идентификатор messageListenerContainerFactory для определения используемого org.springframework.jms.listener.AbstractMessageListenerContainer. | Строка | |
| Message Timestamp Enabled | messageTimestampEnabled | Указывает, должны ли временные метки Timestamp быть включены по умолчанию при отправке сообщений (подсказка для JMS‑брокера). Если брокер принимает подсказку, временная метка устанавливается в 0; если игнорирует — используется обычное значение. | True | Логическое значение |
| Pub Sub No Local | pubSubNoLocal | При включении предотвращает получение сообщений, опубликованных тем же соединением. | False | Логическое значение |
| Receive Timeout | receiveTimeout | Время ожидания для получения сообщений (в миллисекундах). | 1000 | Длинное целое число |
| Recovery Interval | recoveryInterval | Интервал между попытками восстановления (например, при обновлении соединения), в миллисекундах. | 5 000 | Длинное целое число |
| Request Timeout Checker Interval | requestTimeoutCheckerInterval | Задает в миллисекундах, как часто проверять время ожидания запросов/ответов через JMS. Время ожидания определяется параметром Request Timeout. | 1000 | Длинное целое число |
| Synchronous | synchronous | Определяет, следует ли строго использовать синхронную обработку. | False | Логическое значение |
| Temporary Queue Resolver | temporaryQueueResolver | Позволяет задать собственный распределитель для создания временных очередей. Некоторые системы обмена сообщениями предъявляют особые требования к созданию временных очередей. | Строка | |
| Transfer Exception | transferException | При включении (и использовании обмена InOut) отправляет исключение обратно в ответ в виде jakarta.jms.ObjectMessage, если на стороне получателя произошел сбой. Если клиент — Camel, возвращенное исключение повторно генерируется. Примечание: Имеет приоритет над TransferExchange. Перехваченное исключение должно быть сериализуемым. Исходное исключение может быть преобразовано во внешнее. | False | Логическое значение |
| Transfer Exchange | transferExchange | Позволяет передавать не только тело сообщения и заголовки, но и все данные объекта Exchange, проходящего через блок JMS (поля: In body, Out body, Fault body, In headers, Out headers, Fault headers, свойства exchange, exchange exception). Требуется, чтобы объекты были сериализуемыми. Несериализуемые объекты исключаются и регистрируются на уровне WARN. Опцию нужно включить на обеих сторонах: отправителя и получателя. | False | Логическое значение |
| Use Message IDAs Correlation ID | useMessageIDAsCorrelationID | Указывает, следует ли всегда использовать JMSMessageID в качестве JMSCorrelationID для входящих сообщений. | False | Логическое значение |
| Wait For Temporary Reply To To Be Updated Thread Sleeping Time | waitForTemporaryReplyToToBe UpdatedThreadSleepingTime | Интервал в миллисекундах для перехода в спящий режим при ожидании готовности временной очереди ответов. | 100 | Длинное целое число |
| Lazy Create Transaction Manager | lazyCreateTransactionManager | При включении создает JmsTransactionManager, если Transacted=True и не задан TransactionManager. | True | Логическое значение |
| Transaction Manager | transactionManager | Используемый диспетчер транзакций | Строка | |
| Transaction Name | transactionName | Название используемой транзакции | Строка | |
| Transaction Timeout | transactionTimeout | Значение тайм‑аута транзакции (в секундах), если используется режим транзакции. Значение "-1" означает неограниченный тайм‑аут (бессрочное ожидание завершения транзакции). | -1 | Целое число |
| Pattern | pattern | Доступен только для блоков-отправителей Шаблон взаимодействия (Exchange Pattern) для обмена сообщениями. Определяет направление потока данных между его компонентами. Возможные значения:
| Список | |
| Disabled | disabled | Доступен только для блоков-отправителей Определяет, будет ли блок отключен в потоке. В активированном потоке функциональность блока не будет отрабатываться. | False | Логическое значение |
Параметры безопасности
| Название в UI | Название атрибута | Описание | Значение по умолчанию | Тип данных |
|---|---|---|---|---|
| Password | password | Пароль для авторизации на сервере. | Строка | |
| Username | username | Имя пользователя для авторизации на сервере. | Строка |